package com.xo.mall.Lisener;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

@Component
@RocketMQMessageListener(
        topic = "es_pms_product_topic",
        consumerGroup = "es_pms_product_group",
        consumeMode = ConsumeMode.CONCURRENTLY,
        maxReconsumeTimes = 3
)
@Slf4j
public class EsPmsProductListener implements RocketMQListener {


    @Override
    public void onMessage(Object o) {

    }
}
